999c72be0468664c711159cd53deff79e62ee4a1,retrofit-adapters/rxjava/src/test/java/retrofit2/adapter/rxjava/ObservableTest.java,ObservableTest,bodySuccess404,#,62
Before Change
server.enqueue(new MockResponse().setResponseCode(404));
BlockingObservable<String> o = service.body().toBlocking();
try {
o.first();
fail();
} catch (RuntimeException e) {
Throwable cause = e.getCause();
assertThat(cause).isInstanceOf(HttpException.class).hasMessage("HTTP 404 Client Error");
}
}
After Change
service.body().subscribe(subscriber);
subscriber.assertNoValues();
Throwable cause = subscriber.getOnErrorEvents().get(0);
assertThat(cause).isInstanceOf(HttpException.class).hasMessage("HTTP 404 Client Error");
}
@Test public void bodyFailure() {